package com.muyu.kafka.mapper;

import com.muyu.kafka.domain.Data1;
import com.muyu.kafka.domain.Data2;
import com.muyu.kafka.domain.Data3;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

import java.math.BigInteger;
import java.util.Date;
import java.util.List;

/**
 * @ClassName KafkaMapper
 * @Description 描述
 * @Author ShiYu.Cui
 * @Date 2024/4/11 20:28
 */
@Mapper
public interface KafkaMapper {
    Integer findData1(@Param("id") BigInteger id);

    void insertData1(Data1 value);

    void updateData1(Data1 value);

    Integer findData2(@Param("id") BigInteger id);

    void insertData2(Data2 value2);

    void updateData2(Data2 value2);

    Integer findData3(@Param("id") BigInteger id);

    void insertData3(Data3 value);

    void updateData3(Data3 value);
    List<Data1> findData1All();

    Data2 finddata2(@Param("id") BigInteger id);
    Data3 finddata3(@Param("id") BigInteger id);

    void delete1ById(@Param("id") BigInteger id);

    void delete2ById(@Param("id") BigInteger id);

    void delete3ById(@Param("id") BigInteger id);

    List<Data1> findData1ByTime(@Param("time") Date time);
}
